package com.yifeng.repo.controller.kafka.message.constant;

/**
 * Created by daibing on 2024/5/1.
 */
public class KafkaConstant {

    public static final String PROPERTY_TAGS = "TAGS";

    public static final String SUB_EXPRESSION_ALL = "*";

    public static final String SUB_EXPRESSION_SEPARATOR = "\\|\\|";

    public static final String SASL_MECHANISM_VALUE = "SCRAM-SHA-256";

    /**
     * earliest 当各分区下有已提交的offset时，从提交的offset开始消费；无提交的offset时，从头开始消费
     */
    public static final String AUTO_OFFSET_RESET_EARLIEST = "earliest";

    /**
     * latest 当各分区下有已提交的offset时，从提交的offset开始消费；无提交的offset时，消费新产生的该分区下的数据
     */
    public static final String AUTO_OFFSET_RESET_LATEST = "latest";
}
